package com.ajing.logextractor.config;

import lombok.Data;

import java.util.List;
import java.util.Map;

@Data
public class ConsumerConfig {

    private Map<String, Object> kafkaProperties;

    private Integer patchSize;

    private String filePrefix;

    private String filePath;

    private Integer pollRecords;

    private Integer maxBytes;

    private Integer minBytes;

    private Integer maxWaitMs;

    private Integer pullTimeOut;

    private List<CommonHandlerConfig> handlers;
}
